package org.iqiyi.rabbitMq;

import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.context.annotation.Configuration;
/**
 *
 * 如果消息未能投递到目标 queue 里将触发回调 returnCallback ，
 * 一旦向 queue 投递消息未成功，这里一般会记录下当前消息的详细投递数据，
 * 方便后续做重发或者补偿等操作
 * */
@Configuration
public class ReturnCallbackService  implements RabbitTemplate.ReturnCallback {
    @Override
    public void returnedMessage(Message message, int replyCode, String replyText, String exchange, String routingKey) {

    }
}
